package jike.demo18.code02;

import jike.demo18.code02.source.ConfigSource;
import jike.demo18.code02.source.ZookeeperConfigSource;

/**
 * @author oyz
 * @version 1.0.4
 * @description: 测试类
 * @date 2023/3/21 21:48
 */
public class DemoTest {

    public static void main(String[] args) {
        ConfigSource config = new ZookeeperConfigSource("配置zk信息");
        KafkaConfig kafkaConfig = new KafkaConfig(config);
        RedisConfig redisConfig = new RedisConfig(config);

        ScheduledUpdater kafkaUpdater = new ScheduledUpdater(1,1,kafkaConfig);
        ScheduledUpdater redisUpdater = new ScheduledUpdater(1,1,redisConfig);

        kafkaUpdater.run();
        redisUpdater.run();

    }

}
